package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.OuterStatisticData;
import com.navinfo.tripanalysis.offline.pojo.LoadDataParam;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;
import java.util.List;

/**
 * 加载行程服务接口
 * @author 沈东生
 */
public interface LoadTripStatisticService extends Serializable{
    JavaPairRDD<Long, List<OuterStatisticData>> load(SparkSession spark, LoadDataParam param);
}
